//package com.origin.learn.flume.bean;
//
//import com.origin.learn.flume.annotation.FlumeComponentType;
//import lombok.Data;
//import lombok.experimental.Accessors;
//
//import java.util.List;
//import java.util.stream.Collectors;
//import java.util.stream.Stream;
//
///**
// * @Description: Sink组件
// * @Date: 2020/1/8
// * @Time: 9:57
// * @Created by:   dingtao
// * @Modified by:
// * @Modified at:
// */
//@Data
//@Accessors(fluent = true)
////@FlumeComponentType(value = FlumePropertyConstant.SINKS)
//public class FlumeSink extends FlumeComponent {
//    /**
//     * Sink组件连接的Channel列表
//     */
//    private List<FlumeChannel> channels;
//
//    /**
//     * 设置组件名
//     * @param name
//     * @return
//     */
//    public FlumeSink name(String name){
//        super.name(name);
//        return this;
//    }
//
//    /**
//     * 设置数据槽连接的管道
//     * @param channels 管道列表
//     * @return
//     */
//    public FlumeSink setChannels(FlumeChannel ...channels){
//        this.channels = Stream.of(channels).collect(Collectors.toList());
//        return this;
//    }
//}
